package lab82;

import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

/**
 * 
 * SomeCityMapper.java 用来处理已经建立机场的城市的Mapper类
 * 处理已经建立机场的城市的Mapper，处理完Mapper的输出结果为key-value健值对，其中key是城市的名字，value是
 * s_开头后面跟整行数据，输出格式如下： <济南，s_济南 济南飞机场> <青岛，s_青岛 青岛飞机场> .....
 */

public class SomeCityMapper extends Mapper<LongWritable, Text, Text, Text> {

    public static final String LABEL = "s_";

    public void map(LongWritable key, Text value,
            org.apache.hadoop.mapreduce.Mapper<LongWritable, Text, Text, Text>.Context context)
            throws java.io.IOException, InterruptedException {
        // 获取一行切分之后的字符串数组信息
        String[] lines = value.toString().split("\t");
        // 从字符串数组中获取城市的名字
        String cityName = lines[0];
        // 经过处理加上标签之后输出新的健值对
        context.write(new Text(cityName), new Text(LABEL + value.toString()));
    }
}
